package com.springcloud.learn;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.integration.annotation.ServiceActivator;

/**
 * @author Edison_lv  lvchangrong
 * @create 2017/12/15  16:46
 */
@EnableBinding(value = {Sink.class})
public class IntegrationSinkReceiver {

    private static Logger logger = LoggerFactory.getLogger(IntegrationSinkReceiver.class);

    @ServiceActivator(inputChannel = Sink.INPUT)
    public void receive(Object payload){
        logger.info("Received :======"+payload);
    }






}
